//package com.example.ymm.component.mqtt;
//
//import org.eclipse.paho.client.mqttv3.MqttClient;
//import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
//import org.eclipse.paho.client.mqttv3.MqttException;
//import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
//import org.springframework.beans.factory.annotation.Value;
//import org.springframework.context.annotation.Bean;
//import org.springframework.context.annotation.Configuration;
//import org.springframework.web.client.RestTemplate;
//
//@Configuration
//public class MqttConfig {
//
//    @Value("${mqtt.broker-url}")
//    private String brokerUrl;
//
//    @Value("${mqtt.username}")
//    private String username;
//
//    @Value("${mqtt.password}")
//    private String password;
//
//    @Value("${mqtt.client-id}")
//    private String clientId;
//    @Value("${spring.profiles.active}")
//    String PD_MATCH;
//
//
//    @Bean
//    public MqttClient mqttClient() throws MqttException {
//        // 创建MQTT客户端
//        MqttClient client = new MqttClient(brokerUrl, clientId, new MemoryPersistence());
//
//        // 配置连接选项
//        MqttConnectOptions options = new MqttConnectOptions();
//        options.setCleanSession(true);
//        // 如果NanoMQ配置了用户名密码，需要在这里设置
//         options.setUserName(username);
//         options.setPassword(password.toCharArray());
//
//        // 连接到NanoMQ
//        client.connect(options);
//
//        return client;
//    }
//
//
//    @Bean
//    public RestTemplate restTemplate() {
//        return new RestTemplate();
//    }
//
//}
//
